package com.alibaba.common.api.service;

/**
 * 发布者接口
 */
public interface IMQTTPublisherService {
    /**
     * Publish message
     *
     * @param topic
     * @param message
     */
    public void publishMessage(String topic, String message);

    /**
     * Disconnect MQTT Client
     */
    public void disconnect();
}


